//package com.func.boom.config.kafka;
//
//import org.apache.kafka.clients.consumer.ConsumerRecord;
//import org.springframework.kafka.annotation.KafkaListener;
//import org.springframework.stereotype.Component;
//
//import java.util.Optional;
//
///**
// * @author Yulei
// * @date 2020-09-18 13:36:25
// * @desc kafka消费者
// */
//@Component
//public class Consumer {
//
//    @KafkaListener(topics = "boom-boom")
//    public void consumer(ConsumerRecord consumerRecord){
//        Optional<Object> kafkaMassage = Optional.ofNullable(consumerRecord.value());
//
//        if(kafkaMassage.isPresent()){
//            Object o = kafkaMassage.get();
//            System.out.println(o);
//        }
//    }
//
//}
